package org.example;

import org.apache.rocketmq.common.message.MessageExt;
import org.example.mq.ConsumerServer;

/**
 * @author: wf
 * @create: 2025/5/15 17:24
 * @description:
 */
public class TestMain {
    public static void main(String[] args) {
        System.out.println("Hello world!");
    }
    
    
    
    public static class ConsumerServerTest extends ConsumerServer {
        @Override
        public void initConsumerMsg() {
            
        }
        
        @Override
        public boolean receive(MessageExt messageExt) {
            return false;
        }
    }
}